import io.etcd.jetcd.Client;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;

public class mySinkFun extends RichSinkFunction<String> {
    private Client client;

    @Override
    public void open(Configuration parameters) throws Exception {
        client = ETCDUtilL.getEtclClient();
    }

    @Override
    public void close() throws Exception {
//       / client.close();
    }

    @Override
    public void invoke(String value, Context context) throws Exception {
        ETCDUtilL.putEtcdValueByKey("key11", value);
    }
}
